/**
 * 上海中赢金融信息服务有限公司
 * Copyright (c) 2017-2027 Chinazyjr,Inc.All Rights Reserved.
 */

package com.sys.midware.MQ.rocketMQ.config;
/**
 * <b>ClassName:</b> StormConfigKey.java <br/>
 * <b>Description:</b> TODO <br/>
 * <b>Date:</b>     2016年1月29日 下午5:31:20<br/> 
 * @author   mobing
 * @version  	 
 */
public class MQConfigKey {

    
    public static final String KEY_ROCKETMQ_NAME_SERVER = "rocketmq_name_server";
    public static final String KEY_MSG_CONSUMER_THREAD_MIN_SIZE = "msg_consumer_thread_min_size";
    public static final String KEY_MSG_CONSUMER_THREAD_MAX_SIZE = "msg_consumer_thread_max_size";
    public static final String KEY_MSG_PULL_THRESHOLD_QUEUE_SIZE = "msg_pull_threshold_queue_size";
    public static final String KEY_MSG_CONSUME_BATCH_MAX_SIZE = "msg_consume_batch_max_size";
    public static final String KEY_MSG_PULL_BATCH_SIZE = "msg_pull_batch_size";
    public static final String KEY_MSG_CONSUME_CONCURRENTLY_MAX_SPAN_SIZE = "msg_consume_concurrently_max_span_size";
    //以下参数根据应用来配置
    public static final String KEY_MSG_INSTANCE_PRODUCER = "msg_instance_producer";
    public static final String KEY_MSG_INSTANCE_CONSUMER = "msg_instance_consumer";
    
    
    public static final String KEY_MSG_GROUP_PRODUCER = "msg_group_producer";
    public static final String KEY_MSG_GROUP_CONSUMER = "msg_group_consumer";
    public static final String KEY_MSG_SUBSCRIBE_TOPIC = "msg_subscribe_topic";
    public static final String KEY_MSG_TAGS = "msg_tags";
    public static final String KEY_MSG_KEYS = "msg_keys";
}

